Skip to content
This repository has been archived by the owner on May 1, 2024. It is now read-only.

Kafka & Pulsar Transports #658

Open
wants to merge 88 commits into
base: master
Choose a base branch
from
Open

Kafka & Pulsar Transports #658

wants to merge 88 commits into from

Conversation

JarrodJ83
Copy link
Collaborator

No description provided.

Jarrod Johnson and others added 30 commits April 16, 2020 17:23
Create initial KafkaEndpoint
4fefaf3
Create initial KafkaTransport & Protocol
0bb4b55
Create initial ConfluentKafkaSender
f36697c
Expose internals to kafka proj
4c32149
Add a core ITransportProtocol
817c8af
Add project to sln
e9e6404
Add generics for Kafka producer
f20b2f7
Move projects to src dir
3f4cd34
Fix broken refs
3ecdc71
Make KafkaTransport non-generic
4d7f01e
Test KafkaEndpoint
b916039
Add a basic kafka serilaizer
b6b5a59
Remvoe transport from sender (for now)
12dd5f7
Use generic KafkaEndpoint when configuring
4526acf
Add basic end-to-end test
4e345a0
Create KafkaListener
1fc06e2
Make sure Jasper MessageId goes across the wire
e8fef65
Handle commit exception in listener
d27513c
Make sure to pass message to publisher
82489d1
Add listener on StartListening
5d6346f
Leverage ITransporProtocol<> in AzureServiceBus ext
f92f1d5
Enable setting serializers on publisher
0ff0532
Enable setting serializers on consumer
1af638a
Honor endpoint TPL ExecutionOptions
f4141fb
Remove redundant if statement
09ac0d9
Remove unnecessary async and return Task.CompletedTask;
346b39a
Remove redundant property assignment
f764c18
Remove unused usings
330c121
Abstract away IProducer so we can have a common non-generic interface…
2cedd77 
… to leverage
Remove producer/consumer abstractions
9f11917
Jarrod Johnson and others added 30 commits May 6, 2020 17:21
Raise error on Fatal producer errors
bb8c739
Don't default producer/consumer configs to make it easier to fail fast
16bfb1f
Add message key to jasper headers if set on inbound kafka message
676efda
Enable not checking timeout in tracked session
9c609c3
Rename ISendingAgent.StoreAndForward -> Forward for clarity
61994e9 
Not all agents were storing the message first
Add test to make sure publish failures reported to publisher when not…
7ba06ef 
… durable
Check for null Uris to avoid null ref in MS logger abstraction
4d6eb3e
Change listener status
951f60e
Remove duplicate code
08bc4fe
Update Kafka NuGet info
08981e0
Remove unnecessary dependency
e5501a2
Create Pulsar projects
7850ef1
Make internals visible to new Pulsar projects
6329cfd
Enable transports to support multiple schemas
800fd47
Create PulsarTopic for consistency working with Pulsar topics
1d33257
Initial creation of Pulsar transport and tests
a92e9e2
Get properties from incoming Pulsar message
e0cdfd7
Add PulsarEndpointTests
56ae641
Make sure that failed calls return to sender
e20bf6d
Keep Jasper specifics in Endpoint and out of PulsarTopic
63bb8f1
Cleanup topics and subscribers for Pulsar compliance tests
8312c35
Add short delay after creating test harness to allow consumer to latc…
f70c0d2 
…h to transport
Merge pull request #2 from JarrodJ83/feature/reduce-sender-responsibi…
98a72ea 
…lities

Reduce ISender Implementation Responsibilities
Merge pull request #3 from JarrodJ83/feature/pulsar
a9aaba9 
Feature/pulsar
Merge pull request #5 from JarrodJ83/kakfa
cfc5d5d 
Kakfa & Pulsar Transports
Merge from JasperFx/master
467f7b5
Rename ISendingAgent.Forward back to StoreAndForward
97ff5b8
Add Pulsar to docker-compose
c734f99
Rename servcie in docker-compose
7c64cf3
Merge pull request #6 from JarrodJ83/revert-isendingagent-name-change
ef1b73c 
Revert isendingagent name change
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Reviewers
No reviews
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.
1 participant
@JarrodJ83